//package com.dkx.springbootwebsocket.service;
//
//import com.dkx.springbootwebsocket.entity.Message;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.messaging.simp.SimpMessagingTemplate;
//import org.springframework.stereotype.Service;
//
//import java.util.HashMap;
//import java.util.Map;
//import java.util.UUID;
//
///**
// * @Author: 杜科璇
// * @Description: TODO
// * @Date: 2025/10/31 21:23
// * @Version: 1.0
// */
//
//// MessageDebugService.java
//@Service
//@Slf4j
//public class MessageDebugService {
//
//    @Autowired
//    private SimpMessagingTemplate messagingTemplate;
//
//    @Autowired
//    private WebSocketMessageService messageService;
//
//    /**
//     * 发送测试消息
//     */
//    public void sendTestMessage(String fromUser, String toUser, String content) {
//        log.info("发送测试消息: from={}, to={}, content={}", fromUser, toUser, content);
//
//        // 检查目标用户是否在线
//        boolean isOnline = messageService.isUserOnline(toUser);
//        log.info("目标用户在线状态: {} -> {}", toUser, isOnline);
//
//        // 创建测试消息
//        Message message = new Message(
//                UUID.randomUUID().toString(),
//                fromUser,
//                toUser,
//                content,
//                Message.MessageType.P2P,
//                System.currentTimeMillis(),
//                false
//        );
//
//        if (isOnline) {
//            try {
//                // 尝试发送消息
//                messagingTemplate.convertAndSendToUser(toUser, "/queue/messages", message);
//                log.info("测试消息发送成功: {}", message);
//            } catch (Exception e) {
//                log.error("测试消息发送失败: {}", e.getMessage(), e);
//            }
//        } else {
//            log.info("目标用户离线，无法发送测试消息");
//        }
//    }
//
//    /**
//     * 获取所有活跃会话信息
//     */
//    public Map<String, Object> getSessionInfo() {
//        Map<String, Object> result = new HashMap<>();
//
//        // 这里可以添加获取活跃会话的逻辑
//        // 在实际项目中，你可能需要维护一个会话管理器
//
//        result.put("timestamp", System.currentTimeMillis());
//        result.put("message", "会话信息获取功能需要实现");
//
//        return result;
//    }
//}